package com.wu.neihan.service;

import com.wu.util.ConMysql;

public class CommentQueueService extends Thread {
	GatherService gather=new GatherService();
	ConMysql conMysql = new ConMysql();
	
	@Override
	public void run() {
		while (true) {
			String id = "";
			try {
				id = QueueService.getCommentQueue();
				if(!conMysql.checkId("select to_id from mto_comments where to_id='" + id + "' limit 1")){
					gather.caiComtentsInfo(id, 0);
				}
			} catch (Exception e) {
				e.printStackTrace();
			}

		}

	}
}
